/*******************************************************************/
/* @ All Rights Reserved Copyright (C) 2014 broada,Co.,Ltd.        */
/*                                                                 */
/*  NAME      = activemq_openwire_parse.c                          */
/*  NOTE      =                                                    */
/*  DATE      = 2015/05/11 by geyh                                 */
/*******************************************************************/

#ifndef __JMS_OPENWIRE_PARSE_H_
#define __JMS_OPENWIRE_PARSE_H_

#include "frbyte_buffer.h"
#include "frlist.h"
#include "activemq_base_type.h"
#include "activemq_core.h"

int openwire_wireinfo_tightUnmarshal(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, unsigned int ui_data_len, L7session_activeMQ_private *p_st_private);
int openwire_brokerinfo_tightUnmarshal(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, L7session_activeMQ_private *p_st_private);
int openwire_connectioninfo_tightUnmarshal(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, L7session_activeMQ_private *p_st_private);
int openwire_sessioninfo_tightUnmarshal(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, L7session_activeMQ_private *p_st_private);
int openwire_consumerinfo_tightUnmarshal(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, L7session_activeMQ_private *p_st_private);
int openwire_producerinfo_tightUnmarshal(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, L7session_activeMQ_private *p_st_private);
int openwire_producerack_tightUnmarshal(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, L7session_activeMQ_private *p_st_private);
int openwire_transactioninfo_tightUnmarshal(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, L7session_activeMQ_private *p_st_private);
int openwire_keepaliveinfo_tightUnmarshal(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, L7session_activeMQ_private *p_st_private);
int openwire_shutdowninfo_tightUnmarshal(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, L7session_activeMQ_private *p_st_private);
int openwire_removeinfo_tightUnmarshal(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, L7session_activeMQ_private *p_st_private);
int openwire_connectioncontrol_tightUnmarshal(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, L7session_activeMQ_private *p_st_private);
int openwire_messagedispatch_tightUnmarshal(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, L7session_activeMQ_private *p_st_private);
int openwire_map_message_tightUnmarshal(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, L7session_activeMQ_private *p_st_private);
int openwire_text_message_tightUnmarshal(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, L7session_activeMQ_private *p_st_private);
int openwire_stream_message_tightUnmarshal(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, L7session_activeMQ_private *p_st_private);
int openwire_messagepull_tightUnmarshal(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, L7session_activeMQ_private *p_st_private);
int openwire_messageack_tightUnmarshal(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, L7session_activeMQ_private *p_st_private);
int openwire_response_tightUnmarshal(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, L7session_activeMQ_private *p_st_private);
int openwire_exceptionresponse_tightUnmarshal(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, L7session_activeMQ_private *p_st_private);

int openwire_removesubscriptioninfo_tightUnmarshal(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, L7session_activeMQ_private *p_st_private);
int openwire_controlcommand_tightUnmarshal(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, L7session_activeMQ_private *p_st_private);
int openwire_flushcommand_tightUnmarshal(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, L7session_activeMQ_private *p_st_private);
int openwire_connectionerror_tightUnmarshal(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, L7session_activeMQ_private *p_st_private);
int openwire_consumercontrol_tightUnmarshal(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, L7session_activeMQ_private *p_st_private);

int openwire_tightUnmarshal(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, L7session_activeMQ_private *p_st_private);

int openwire_messageack_tightUnmarshal_detect(Frbyte_Packet *p_st_data, int i_tightEncodingEnabled, int i_cacheEnabled, int i_openwire_version);
int openwire_messagedispatch_tightUnmarshal_detect(Frbyte_Packet *p_st_data, int i_tightEncodingEnabled, int i_cacheEnabled, int i_openwire_version);

#endif
